package com.aotain.jupiter.flink;

import java.util.List;

import com.aotain.common.mongo.DataColumn;

public class MongoSinkObject {

	public enum DML {
		INSERT,UPDATE
	}
	
	private String tablename;
	private List<DataColumn> importdata;
	private DML dmltype = DML.INSERT;
	private List<DataColumn> filterdata;
	
	
	public void setTableName(String tableName) {
		tablename = tableName;
	}
	
	public String getTableName() {
		return tablename;
	}
	
	public void setImportData(List<DataColumn> insertData) {
		importdata = insertData;
	}
	
	public List<DataColumn> getImportData() {
		return importdata;
	}
	
	public void setDmlType(DML dmlType) {
		dmltype = dmlType;
	}
	
	public DML getDmlType() {
		return dmltype;
	}
	
	public void setFilterData(List<DataColumn> filterData) {
		filterdata = filterData;
	}
	
	public List<DataColumn> getFilterData() {
		return filterdata;
	}
}


